package com.yangzb.flink.sql.sample;

/**
 * @author: yangzb
 * @date 2023/2/21 10:31 AM
 **/
public class FlinkSql {
    public static void main(String[] args) throws Exception {
        System.setProperty("HADOOP_USER_NAME", "root");
        CliOptions cliOptions = CliOptionsParser.parseClient(args);
        SqlSubmit sqlSubmit = new SqlSubmit(cliOptions.getJobName(), cliOptions.getSqlFilePath());
        sqlSubmit.run();
    }
}
